package com.yedean.mall.reactor8;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.util.Arrays;
import java.util.List;
import java.util.stream.Stream;

public class TestReactor {
    public static void main(String[] args) {
        //just方法可以直接声明我们相关的元素
        Flux.just(1,2,3,4).subscribe(System.out::println);

        Mono.just(1).subscribe(System.out::println);
        
        
        
        //其他的方法
        //数组
//        Integer[] array ={1,2,3,4};
//        Flux.fromArray(array);
//        
//        //集合
//        List<Integer> list = Arrays.asList(array);
//        Flux.fromIterable(list);
//        
//        //stream流
//        Flux.fromStream(Stream.of(list));
        
        
        
    }
}
